package com.mp.mqtt.service;

import com.alibaba.fastjson.JSONObject;
import com.mp.mqtt.dto.DeviceSendData;

/**
 * @Auther adidasshe@mp.cn
 * 开启一个线程，读取缓存队列数据写入数据库
 */
public interface DataToDbService {
    /**
     * 向设备数据表添加数据
     */
    public void addDeviceData(Long id, DeviceSendData obj);

    /**
     *
     */
    public void addDeviceInfo(String deviceId, DeviceSendData obj);

    /**
     * 开启线程，获取缓存数据
     */
    public void getData();

    /**
     * 定时开启线程，获取缓存数据
     */
    public void getDataByScheduled();

    /**
     * 开启事务处理数据
     */
    public void handlerData();

    /**
     * 获取数据库设备信息放入缓存池deviceIds中
     */
    public void getDeviceId();

    /**
     * 初始化设备信息线程池
     */
    public void init();

}
